b2dccea2bb5fedc66cbfbbc26b06b9df2f9ae351,data-fabric/src/main/java/com/continuuity/data2/transaction/queue/hbase/coprocessor/DequeueScanObserver.java,DequeueScanObserver,preScannerOpen,#ObserverContext#Scan#RegionScanner#,52

Before Change



    Filter existing = scan.getFilter();
    Filter combined = new FilterList(FilterList.Operator.MUST_PASS_ALL, existing, dequeueFilter);
    scan.setFilter(combined);

    return super.preScannerOpen(e, scan, s);
  }

After Change


    Filter dequeueFilter = new DequeueFilter(queueName, consumerConfig, tx);

    Filter existing = scan.getFilter();
    if (existing != null) {
      Filter combined = new FilterList(FilterList.Operator.MUST_PASS_ALL, existing, dequeueFilter);
      scan.setFilter(combined);
    } else {
      scan.setFilter(dequeueFilter);
    }